大数据
flink table与datastre 标签描述

(文章目录) 本文是Flinktableapi与datastreamapi的集成的第一篇,主要介绍了集成的概述、tableapi与datastreamapi相互转换的三个示例以及其集成的说明(即maven依赖、import、配置以及执行行为),并以具体的示例进行说明。本文依赖flink、kafka集群能正常使用。本文分为3个部分,即集成概述、三个入门示例、集成说明。本文的示例是在Flink1.17版本中运行。 一、TableAPI与DataStreamAPI集成 1、概述 在定义数据处理管道时,TableAPI和DataStreamAPI同样重要。 DataStreamAPI在一个相对低级的...